package com.cx.thread.test;

public class ConSumerRunnable implements Runnable{
    private Consumer consumer;

    public ConSumerRunnable(Consumer consumer) {
        this.consumer = consumer;
    }

    @Override
    public void run() {
        consumer.pull();//拉取数据
    }
}